package com.rdc.qingkou.retrofitService;

import com.rdc.qingkou.entity.MessageNewsNumResult;
import com.rdc.qingkou.entity.MessageResult;

import io.reactivex.Observable;
import retrofit2.http.GET;
import retrofit2.http.Query;


public interface IMessageService {

    /**
     * 获取信息的接口
     *
     * @param userId
     * @param currentPage  当前页数
     * @return
     */
    @GET("news/getNews")
    Observable<MessageResult> getNews(@Query("userId") Integer userId, @Query("currentPage") Integer currentPage);

    /**
     * 获取未读消息的数目的接口
     *
     * @param userId
     * @return
     */
    @GET("news/getNewsNum")
    Observable<MessageNewsNumResult> getUnReadNewsNum(@Query("userId") Integer userId);

    /**
     * 获取更多信息的接口
     *
     * @param userId
     * @param currentPage  获取当前页数(从第一页开始)
     * @return
     */
    @GET("news/getMoreNews")
    Observable<MessageResult> getMoreNews(@Query("userId") Integer userId,@Query("currentPage") Integer currentPage);

    /**
     * 修改消息状态的接口
     *
     * @param userId
     * @return
     */
    @GET("news/getNewsNum")
    Observable<MessageNewsNumResult> updateNews(@Query("userId") Integer userId);
}
